package com.edu.robot.common.service;

import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;

/**
 * @program: KQAIA
 * @description:
 * @author: 无恙
 * @create: 2025-03-30 16:30
 **/


public interface ChannelManger {

	/**
	 * 创建sse
	 * @param uid
	 * @return
	 */
	SseEmitter createSse(String uid);

	/**
	 * 发送消息
	 * @param uid
	 * @param message
	 * @return
	 */
	boolean sendMessage(String uid,String messageId, String message);

	/**
	 * 关闭sse
	 * @param uid
	 */
	void closeSse(String uid);
}
